package indi.zhifa.study2025.flinkcdc.binlog;

import com.alibaba.fastjson2.annotation.JSONField;
import lombok.Data;

@Data
public class BinlogSource {
    String version;
    String connector;
    String name;
    @JSONField(name = "ts_ms")
    String tsMs;
    String table;
    @JSONField(name = "server_id")
    String serverId;
    String gtid;
    String file;
    Integer pos;
    Integer row;
}
